517295d5b2a7874f37cf7c1ae5968abc1114be93,src/main/java/net/hasor/rsf/rpc/context/AbstractRsfContext.java,Transport,sendResponse,#InterAddress#ResponseInfo#,230
Before Change
@Override
public void sendResponse(InterAddress target, ResponseInfo info) {
try {
rsfNetManager.getChannel(target).get().sendData(info, null);
} catch (Throwable e) {
addressPool.invalidAddress(target);//异常地�失效
logger.error("sendResponse - " + e.getMessage(), e);
After Change
@Override
public void sendResponse(InterAddress target, ResponseInfo info) {
try {
RsfNetChannel channel = rsfNetManager.getChannel(target);
if (channel != null) {
channel.sendData(info, null);
} else {
throw new RsfException(ProtocolStatus.NetworkError, "Invalid address ->" + target.toHostSchema());
}
} catch (Throwable e) {
addressPool.invalidAddress(target);//异常地�失效